package com.chukun.flink.stream.action.click;

import org.apache.flink.api.common.eventtime.TimestampAssigner;

/**
 * 获取kafka事件时间生成策略
 */
public class TimeStampExtractor implements TimestampAssigner<UserBehaviorEvent> {
    @Override
    public long extractTimestamp(UserBehaviorEvent element, long recordTimestamp) {
        return element.getTs();
    }
}